import os
from celery import Celery

#设置环境变量，加载Django的settings
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings')

#创建Celery Application
celery_app=Celery('project')
celery_app.config_from_object('worker.config')
celery_app.autodiscover_tasks()

def call_by_worker(func):
  #将任务在Celery中异步执行
  task=celery_app.task(func)  #可以定义为装饰器
  return task.delay

# @celery_app.task
# def add(x,y):
#   return x+y
#add=celery_app.task(add)
#add(x,y)